<?php

class ADODB_pdo_pgsql extends ADODB_pdo {

    var $metaDatabasesSQL = "select datname from pg_database where datname not in ('template0','template1') order by 1";
    var $metaTablesSQL = "select tablename,'T' from pg_tables where tablename not like 'pg\_%'
	and tablename not in ('sql_features', 'sql_implementation_info', 'sql_languages',
	 'sql_packages', 'sql_sizing', 'sql_sizing_profiles') 
	union 
        select viewname,'V' from pg_views where viewname not like 'pg\_%'";
    //"select tablename from pg_tables where tablename not like 'pg_%' order by 1";
    var $isoDates = true; // accepts dates in ISO format
    var $sysDate = "CURRENT_DATE";
    var $sysTimeStamp = "CURRENT_TIMESTAMP";
    var $blobEncodeType = 'C';
    var $metaColumnsSQL = "SELECT a.attname,t.typname,a.attlen,a.atttypmod,a.attnotnull,a.atthasdef,a.attnum 
		FROM pg_class c, pg_attribute a,pg_type t 
		WHERE relkind in ('r','v') AND (c.relname='%s' or c.relname = lower('%s')) and a.attname not like '....%%'
AND a.attnum > 0 AND a.atttypid = t.oid AND a.attrelid = c.oid ORDER BY a.attnum";
    // used when schema defined
    var $metaColumnsSQL1 = "SELECT a.attname, t.typname, a.attlen, a.atttypmod, a.attnotnull, a.atthasdef, a.attnum 
FROM pg_class c, pg_attribute a, pg_type t, pg_namespace n 
WHERE relkind in ('r','v') AND (c.relname='%s' or c.relname = lower('%s'))
 and c.relnamespace=n.oid and n.nspname='%s' 
	and a.attname not like '....%%' AND a.attnum > 0 
	AND a.atttypid = t.oid AND a.attrelid = c.oid ORDER BY a.attnum";
    var $metaKeySQL = "SELECT ic.relname AS index_name, a.attname AS column_name,i.indisunique AS unique_key, i.indisprimary AS primary_key 
	FROM pg_class bc, pg_class ic, pg_index i, pg_attribute a WHERE bc.oid = i.indrelid AND ic.oid = i.indexrelid AND (i.indkey[0] = a.attnum OR i.indkey[1] = a.attnum OR i.indkey[2] = a.attnum OR i.indkey[3] = a.attnum OR i.indkey[4] = a.attnum OR i.indkey[5] = a.attnum OR i.indkey[6] = a.attnum OR i.indkey[7] = a.attnum) AND a.attrelid = bc.oid AND bc.relname = '%s'";
    var $hasAffectedRows = true;
    var $hasLimit = false;
    var $true = 't';
    var $false = 'f';
    var $fmtDate = "'Y-m-d'";
    var $fmtTimeStamp = "'Y-m-d G:i:s'";
    var $hasMoveFirst = true;
    var $hasGenID = true;
    var $_genIDSQL = "SELECT NEXTVAL('%s')";
    var $_genSeqSQL = "CREATE SEQUENCE %s START %s";
    var $_dropSeqSQL = "DROP SEQUENCE %s";
    var $metaDefaultsSQL = "SELECT d.adnum as num, d.adsrc as def from pg_attrdef d, pg_class c where d.adrelid=c.oid and c.relname='%s' order by d.adnum";
    var $random = 'random()';
    var $concat_operator = '||';

    function _init($parentDriver) {

        $parentDriver->hasTransactions = false;
        $parentDriver->hasInsertID = true;
        $parentDriver->_nestedSQL = true;
    }

    function ServerInfo() {
        $arr['description'] = ADOConnection::GetOne("select version()");
        $arr['version'] = ADOConnection::_findvers($arr['description']);
        return $arr;
    }

    function SelectLimit($sql, $nrows = -1, $offset = -1, $inputarr = false, $secs2cache = 0) {
        $offsetStr = ($offset >= 0) ? " OFFSET $offset" : '';
        $limitStr = ($nrows >= 0) ? " LIMIT $nrows" : '';
        if ($secs2cache)
            $rs = $this->CacheExecute($secs2cache, $sql . "$limitStr$offsetStr", $inputarr);
        else
            $rs = $this->Execute($sql . "$limitStr$offsetStr", $inputarr);

        return $rs;
    }

    function MetaTables($ttype = false, $showSchema = false, $mask = false) {
        $info = $this->ServerInfo();
        if ($info['version'] >= 7.3) {
            $this->metaTablesSQL = "select tablename,'T' from pg_tables where tablename not like 'pg\_%'
			  and schemaname  not in ( 'pg_catalog','information_schema')
	union 
        select viewname,'V' from pg_views where viewname not like 'pg\_%'  and schemaname  not in ( 'pg_catalog','information_schema') ";
        }
        if ($mask) {
            $save = $this->metaTablesSQL;
            $mask = $this->qstr(strtolower($mask));
            if ($info['version'] >= 7.3)
                $this->metaTablesSQL = "
select tablename,'T' from pg_tables where tablename like $mask and schemaname not in ( 'pg_catalog','information_schema')  
 union 
select viewname,'V' from pg_views where viewname like $mask and schemaname  not in ( 'pg_catalog','information_schema')  ";
            else
                $this->metaTablesSQL = "
select tablename,'T' from pg_tables where tablename like $mask 
 union 
select viewname,'V' from pg_views where viewname like $mask";
        }
        $ret = ADOConnection::MetaTables($ttype, $showSchema);

        if ($mask) {
            $this->metaTablesSQL = $save;
        }
        return $ret;
    }

    function MetaColumns($table, $normalize = true) {
        global $ADODB_FETCH_MODE;

        $schema = false;
        $this->_findschema($table, $schema);

        if ($normalize)
            $table = strtolower($table);

        $save = $ADODB_FETCH_MODE;
        $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
        if ($this->fetchMode !== false)
            $savem = $this->SetFetchMode(false);

        if ($schema)
            $rs = $this->Execute(sprintf($this->metaColumnsSQL1, $table, $table, $schema));
        else
            $rs = $this->Execute(sprintf($this->metaColumnsSQL, $table, $table));
        if (isset($savem))
            $this->SetFetchMode($savem);
        $ADODB_FETCH_MODE = $save;

        if ($rs === false) {
            $false = false;
            return $false;
        }
        if (!empty($this->metaKeySQL)) {
            $ADODB_FETCH_MODE = ADODB_FETCH_ASSOC;

            $rskey = $this->Execute(sprintf($this->metaKeySQL, ($table)));
            $keys = $rskey->GetArray();
            if (isset($savem))
                $this->SetFetchMode($savem);
            $ADODB_FETCH_MODE = $save;

            $rskey->Close();
            unset($rskey);
        }

        $rsdefa = array();
        if (!empty($this->metaDefaultsSQL)) {
            $ADODB_FETCH_MODE = ADODB_FETCH_ASSOC;
            $sql = sprintf($this->metaDefaultsSQL, ($table));
            $rsdef = $this->Execute($sql);
            if (isset($savem))
                $this->SetFetchMode($savem);
            $ADODB_FETCH_MODE = $save;

            if ($rsdef) {
                while (!$rsdef->EOF) {
                    $num = $rsdef->fields['num'];
                    $s = $rsdef->fields['def'];
                    if (strpos($s, '::') === false && substr($s, 0, 1) == "'") {
                        $s = substr($s, 1);
                        $s = substr($s, 0, strlen($s) - 1);
                    }

                    $rsdefa[$num] = $s;
                    $rsdef->MoveNext();
                }
            } else {
                ADOConnection::outp("==> SQL => " . $sql);
            }
            unset($rsdef);
        }

        $retarr = array();
        while (!$rs->EOF) {
            $fld = new ADOFieldObject();
            $fld->name = $rs->fields[0];
            $fld->type = $rs->fields[1];
            $fld->max_length = $rs->fields[2];
            if ($fld->max_length <= 0)
                $fld->max_length = $rs->fields[3] - 4;
            if ($fld->max_length <= 0)
                $fld->max_length = -1;
            if ($fld->type == 'numeric') {
                $fld->scale = $fld->max_length & 0xFFFF;
                $fld->max_length >>= 16;
            }
            $fld->has_default = ($rs->fields[5] == 't');
            if ($fld->has_default) {
                $fld->default_value = $rsdefa[$rs->fields[6]];
            }
            if ($rs->fields[4] == $this->true) {
                $fld->not_null = true;
            }
            if (is_array($keys)) {
                foreach ($keys as $key) {
                    if ($fld->name == $key['column_name'] AND $key['primary_key'] == $this->true)
                        $fld->primary_key = true;
                    if ($fld->name == $key['column_name'] AND $key['unique_key'] == $this->true)
                        $fld->unique = true; // What name is more compatible?
                }
            }

            if ($ADODB_FETCH_MODE == ADODB_FETCH_NUM)
                $retarr[] = $fld;
            else
                $retarr[($normalize) ? strtoupper($fld->name) : $fld->name] = $fld;

            $rs->MoveNext();
        }
        $rs->Close();
        if (empty($retarr)) {
            $false = false;
            return $false;
        } else
            return $retarr;
    }

}

?>
